/*
 * core_mqtt.h
 *
 *  Created on: 2021年9月22日
 *      Author: LF
 */

#ifndef SRC_MQTT_TRANSPORT_H_
#define SRC_MQTT_TRANSPORT_H_

/*  连接到mqtt服务器   */
extern	int	transport_open(char *host, int port);

/* 关闭连接    */
extern	int	transort_close(void);

/*  发送报文给mqtt   */
extern	int	transport_sendPacketBuffer(unsigned char *buf, int buflen);

/*  接收mqtt的报文   */
extern	int	transport_getdata(unsigned char *buf,int count);

/*  清楚接受报文   */
extern	void transport_clearBuf(void);



#endif /* SRC_MQTT_TRANSPORT_H_ */
